package com.exd.flink.common;

import org.apache.flink.util.OutputTag;

import com.exd.flink.domain.AlgorithmStatusBean;
import com.exd.flink.domain.ResourcesBean;
import com.exd.flink.domain.VComputeBean;
import com.exd.flink.domain.VersionBean;

/**
 * 描述: 分流标签
 * 创建人: 赵兴炎
 * 日期: 2022年9月13日
 */
public class OutputVComputeTagBase {
	
	/**
	 * 版本数据
	 */
	public static OutputTag<VersionBean> VERSION_DATA = new OutputTag<VersionBean>("VERSION_DATA"){private static final long serialVersionUID = 1L;};
	
	/**
	 * 车辆数据
	 */
	public static OutputTag<String> VIN_DATA = new OutputTag<String>("VIN_DATA"){private static final long serialVersionUID = 1L;};
	
	/**
	 * 算法状态数据
	 */
	public static OutputTag<AlgorithmStatusBean> ALGORITHM_STATUS_DATA = new OutputTag<AlgorithmStatusBean>("ALGORITHM_STATUS_DATA"){private static final long serialVersionUID = 1L;};
	
	/**
	 * 资源监控数据
	 */
	public static OutputTag<ResourcesBean> RESOUCRES_DATA = new OutputTag<ResourcesBean>("RESOUCRES_DATA"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM VCompute 解析正常数据
	 */
	public static OutputTag<VComputeBean> BDCM_ANALYTICAL_VCOMPUTE_OK = new OutputTag<VComputeBean>("BDCM_ANALYTICAL_VCOMPUTE_OK"){private static final long serialVersionUID = 1L;};

	/**
	 * VDCM VCompute 解析正常数据
	 */
	public static OutputTag<VComputeBean> VDCM_ANALYTICAL_VCOMPUTE_OK = new OutputTag<VComputeBean>("VDCM_ANALYTICAL_VCOMPUTE_OK"){private static final long serialVersionUID = 1L;};

}
